import { map, OperatorFunction, pipe } from "rxjs";

/**
 * @public
 *
 * 当源Observable发送过来一个值的时候，把发送来的值直接映射成指定的值。
 * @param value - Observable接收到值的时候要映射后的值.
 * @returns 由映射后的值组成的Observable函数
 */
export function mapTo<R>(value: R): OperatorFunction<unknown, R> {
  return pipe(
    map(() => value)
  )
}